package com.tianji.aigc.service;

import com.tianji.aigc.domain.vo.ChatEventVO;
import reactor.core.publisher.Flux;

public interface IChatService {
    /**
     * 1、流式聊天 （Day1 - 随堂3）
     * @param chatDTO
     * @return
     */
    Flux<ChatEventVO> chat(String question, String sessionId);

    /**
     * 2、流式聊天 （Day1 - 随堂4）
     * @param chatDTO
     * @return
     */
    void stop(String sessionId);
}
